package com.gupao.javavip.netty.push.client.processor.handler;

import com.gupao.javavip.netty.push.api.MsgType;
import io.netty.channel.ChannelHandlerContext;
import lombok.extern.apachecommons.CommonsLog;

@CommonsLog
public class MultiplePushMsgRequestClientHandler extends PushMsgRequestClientHandler {

    public MultiplePushMsgRequestClientHandler() {
        super(MsgType.MSG);
    }

    @Override
    protected void whenActive(ChannelHandlerContext ctx) {
        //循环发送，模拟粘包场景
        for (int i = 0; i < 100; i++) {
            super.whenActive(ctx);
        }
    }
}
